#include "subscriber.h"
#include <iostream>

SubscriberEndpoint::SubscriberEndpoint(const std::string& address) {
    context = zmq::context_t();  // 使用默认构造函数初始化 context
    subscriber = zmq::socket_t(context, zmq::socket_type::sub);  // 使用 context 初始化 subscriber
    subscriber.connect(address);  // 连接到指定地址
    subscriber.set(zmq::sockopt::subscribe, "");  // 订阅所有消息
}

void SubscriberEndpoint::receiveMessage() {
    zmq::message_t message;
    subscriber.recv(message, zmq::recv_flags::none);  // 接收消息
    std::cout << "Received: " << message.to_string() << std::endl;
}
